//package com.rp.article.stream;
//
//import org.springframework.cloud.stream.annotation.Input;
//import org.springframework.cloud.stream.annotation.Output;
//import org.springframework.messaging.MessageChannel;
//import org.springframework.messaging.SubscribableChannel;
//import org.springframework.stereotype.Component;
//
///**
// * 声明构建通道channel
// */
//@Component
//public interface MyStreamChannel {
//    String OUTPUT = "myOutput";
//    String INPUT = "myInput";
//
//    @Output(MyStreamChannel.OUTPUT)
//    MessageChannel output();
//
//    @Input(MyStreamChannel.INPUT)
//    SubscribableChannel input();
//}
